package xuecheng.tool.mq.redis;

import java.lang.annotation.*;

/**
 * 自定义 redismq 主题订阅监听类注解
 *
 * @author PengXueCheng
 * @version 1.0.0
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RedisMqMessageListener {

    /**
     * 队列主题名称
     *
     * @return
     */
    String topic();

    /**
     * 消费者实例个数
     *
     * @return
     */
    int consumerCount() default 16;

}
